package io.renren.modules.task.rabbitmq;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

import java.util.Timer;
import java.util.TimerTask;

/**
 * @Author: 蔡翔
 * @Date: 2019/7/9 13:29
 * @Version 1.0
 */
@Service
public class MQReceiver {
    private static Logger logger = LoggerFactory.getLogger(MQReceiver.class);


    @RabbitListener(queues=MQConfig.QUEUE) //说明Listener 监听的是MQConfig.QUEUE 这个队列。
    public void receive(String message){
        sleepk();

        logger.info("rabbitMQ-- receive message"+message);
    }

    public void sleepk(){
        try {
            Thread.sleep(100000);
        }catch (Exception e){

        }
    }

    @RabbitListener(queues=MQConfig.TOPIC_QUEUE1) //说明Listener 监听的是MQConfig.TOPIC_QUEUE1 这个队列。
    public void receiveTopic1(String message){
        logger.info("rabbitMQTopic1-- receive message"+message);
    }

    @RabbitListener(queues=MQConfig.TOPIC_QUEUE2) //说明Listener 监听的是MQConfig.TOPIC_QUEUE2 这个队列。
    public void receiveTopic2(String message){
        logger.info("rabbitMQTopic2-- receive message"+message);
    }

    /*@RabbitListener(queues=MQConfig.HEADERS_QUEUE) //说明Listener 监听的是MQConfig.TOPIC_QUEUE2 这个队列。
    public void receiveHeaders(byte[] message){  //因为我们发送的是一个字节数组，所以这里接受的也是一个字节数组。
        logger.info("rabbitMQHeaders-- receive message"+new String(message));
    }*/

}
